f4f5157ab6579fea149fe633e44b5b878c187d3f,jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java,CompressExtension,decompress,#number[]#,132
Before Change
while (decompressor.getRemaining() > 0 && !decompressor.finished())
{
byte[] output = new byte[Math.min(input.length * 2, 32 * 1024)];
int decompressed = decompressor.inflate(output);
if (decompressed == 0)
{
if (decompressor.needsInput())
After Change
protected void decompress(ByteAccumulator accumulator, ByteBuffer buf)
throws DataFormatException
{
if ((buf == null) || (!buf.hasRemaining()))
{
return;
}
byte[] output = new byte[1024];
if (inflater.needsInput() && !supplyInput(inflater, buf))
{
LOG.debug("Needed input, but no buffer could supply input");
return;
}
int read = 0;
while ((read = inflater.inflate(output)) >= 0)
{
if (read == 0)
{